package com.ynet.eq.haiqing.module.mqtt;

import org.eclipse.paho.client.mqttv3.MqttMessage;

/**
 * @author 胡超雄
 * @date 2021/7/1 16:21
 * @desc  mqtt 策略抽象类
 */
public  abstract class MqttMessageStrategy {

    /**
     * 处理消息
     * @param s
     * @param message
     */
    public  abstract void  processMessage(String s, MqttMessage message);


}
